package rdd

import org.apache.spark.{SparkConf, SparkContext}
import org.apache.spark.rdd.RDD

object Spark02_RDD_File1 {
  def main(args: Array[String]): Unit = {
  val sparkConf=new SparkConf().setMaster("local[*]").setAppName("RDD_File")
  val sc = new SparkContext(sparkConf)
  val textRDD = sc.wholeTextFiles("data/test*.txt")
  //    val textRDD: RDD[String] = sc.textFile("F:\\ComputeDb\\XUANZE\\PROD.XPA.ATSN.MAN.MESSAGECHECKER.EQUIPMENTSTATECHANGE.PUB.V1")

  textRDD.collect().foreach(println)
  sc.stop()
  }
}
